package com.ocom.mqsubsidy.business.ConsPerReports.impl;

import com.ocom.mqsubsidy.business.ConsPerReports.ConsPerReportsService;
import com.ocom.mqsubsidy.utils.ConsPerReportsProductUitl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class ConsPerReportsServiceImpl implements ConsPerReportsService {

    private final Logger log = LoggerFactory.getLogger(ConsPerReportsServiceImpl.class);

    @Autowired
    private ConsPerReportsProductUitl consPerReportsProductUitl;

    /**
     * 处理人员图片
     */
    public void handle(String msg) {

        log.info(" consPerReports-mq-开始【{}】",msg);
        //消息队列调用减库存接口  优先级越高越先执行完

        consPerReportsProductUitl.subsidySend(msg,15);

        log.info(" consPerReports-完成【{}】",msg);

    }
}
